package com.dabai.iot.mqtt.event;

import io.vertx.mqtt.MqttEndpoint;
import io.vertx.mqtt.messages.MqttPublishMessage;

/**
 * 客户端消息监听
 *
 * @author kev1n
 */
public interface IMqttMessageListener {

    /**
     * 监听到消息
     */
    void onMessage(MqttEndpoint endpoint, MqttPublishMessage mqttMessage);

}
